pull_data->n_outstanding_content_write_requests == 0);
gboolean current_idle = current_fetch_idle && current_write_idle;
- g_debug ("pull: scanning: %u fetching: %u staging: %u",
- !pull_data->metadata_scan_complete, !current_fetch_idle, !current_write_idle);
-
throw_async_error (pull_data, error);
/* This is true in the phase when we're fetching refs */
}
if (pull_data->metadata_scan_complete && current_idle)
- g_main_loop_quit (pull_data->loop);
+ {
+ g_debug ("pull: metadata scan complete and idle, exiting mainloop");
+
+ g_main_loop_quit (pull_data->loop);
+ }
}
static gboolean
check_outstanding_requests_handle_error (pull_data, local_error);
}
+static void
+note_metadata_not_complete (OtPullData *pull_data)
+{
+ if (pull_data->metadata_scan_complete)
+ g_debug ("pull: Transition metadata scan complete -> not complete");
+ pull_data->metadata_scan_complete = FALSE;
+}
+
static void
on_metadata_writed (GObject *object,
GAsyncResult *result,
goto out;
}
- pull_data->metadata_scan_complete = FALSE;
+ note_metadata_not_complete (pull_data);
ot_waitable_queue_push (pull_data->metadata_objects_to_scan,
pull_worker_message_new (PULL_MSG_SCAN,
g_variant_ref (fetch_data->object)));
{
pull_data->checking_metadata_scan_complete = FALSE;
if (msg->d.idle_serial == pull_data->idle_serial)
- pull_data->metadata_scan_complete = TRUE;
+ {
+ g_debug ("marking metadata scan as complete");
+ pull_data->metadata_scan_complete = TRUE;
+ }
}
else if (msg->t == PULL_MSG_FETCH || msg->t == PULL_MSG_FETCH_DETACHED_METADATA)
{
gboolean is_detached_meta;
- pull_data->metadata_scan_complete = FALSE;
+ note_metadata_not_complete (pull_data);
is_detached_meta = msg->t == PULL_MSG_FETCH_DETACHED_METADATA;